package cn.dm.quickstart;

import com.lmax.disruptor.EventHandler;


public class OrderEventHandler implements EventHandler<OrderEvent> {

    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws InterruptedException {
        // Thread.sleep(Integer.MAX_VALUE);
        // System.err.println("消费者: " + event.getValue());
        System.err.println(String.format("消费者消费了订单:%s", event));
    }
}
